package com.study.bigdata.spark.core.rdd.acc

import org.apache.spark.{SparkConf, SparkContext}

object Scala01_Acc {
  def main(args: Array[String]): Unit = {

    val conf = new SparkConf().setMaster("local[*]").setAppName("WordCount")
    val sc = new SparkContext(conf)

    val rdd = sc.makeRDD(List(1,2,3,4),2)

    // TODO 1.创建累加器
    val sum = sc.longAccumulator("sum")

    rdd.foreach(
      num =>{
        // 2.使用累加器
        sum.add(num)
      }
    )
    // 3.结果打印
    println(sum.value)
    sc.stop()//10

  }

}
